package com.wpen.unit.core.service;

import com.wpen.unit.core.ddo.JobAgentBindingDo;
import com.wpen.unit.core.ddo.JobRunningDo;
import com.wpen.unit.infra.mybatis.job.po.AgentRegistryPo;
import com.wpen.unit.infra.mybatis.job.po.JobExec1LogPo;
import com.wpen.unit.infra.mybatis.job.po.JobUndoPlanPo;
import com.wpen.unit.infra.mybatis.job.po.TaskInfoPo;
import com.wpen.unit.web.dto.ContextResponse;

/**
 *
 *
 * @author Wang Peng
 * @date 2022年12月18日
 * 
 */
public interface CommunityHandler {

    public JobAgentBindingDo updateBeforeSend(JobUndoPlanPo jobUndoPlanPo, JobExec1LogPo jobExec1LogPo,
            AgentRegistryPo agentRegistryPo, TaskInfoPo taskInfoPo);

    public void updateAfterSendSocketTimeoutException(JobRunningDo jobRunningDo);

    public void checkFinished(JobRunningDo jobRunningDo, ContextResponse response);
    
    public void checkTaskFinished(Long batchLogId);
}
